4996d8ffd8fe9cd56751b2daba076fe87e6220a3,fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsUrlQueueService.java,EsUrlQueueService,updateSessionId,#String#String#,83
Before Change
@Override
public void updateSessionId(final String oldSessionId, final String newSessionId) {
SearchResponse response =
ActionGetUtil.actionGet(getClient().prepareSearch(index).setTypes(type).setSearchType(SearchType.SCAN).setScroll(new TimeValue(scrollTimeout))
.setQuery(QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, oldSessionId))).setSize(scrollSize)
.execute());
while (true) {
response =
ActionGetUtil.actionGet(getClient().prepareSearchScroll(response.getScrollId()).setScroll(new TimeValue(scrollTimeout)).execute());
final SearchHits searchHits = response.getHits();
if (searchHits.hits().length == 0) {
After Change
@Override
public void updateSessionId(final String oldSessionId, final String newSessionId) {
SearchResponse response = getClient()
.get(c -> c.prepareSearch(index).setTypes(type).setSearchType(SearchType.SCAN).setScroll(new TimeValue(scrollTimeout))
.setQuery(QueryBuilders.boolQuery().filter(QueryBuilders.termQuery(SESSION_ID, oldSessionId))).setSize(scrollSize)
.execute());
while (true) {
final SearchResponse prevResponse = response;
response = getClient()